skip += value_len;
}
}
s = _fs.open(getPathForKey(k));
ByteStreams.skipFully(s, skip);
ByteStreams.readFully(s, b);
assert v.isPersisted();
skip += value_len;
}
}
Path p = getPathForKey(k);
FileSystem fs = FileSystem.get(p.toUri(), CONF);
s = fs.open(p);
ByteStreams.skipFully(s, skip);
ByteStreams.readFully(s, b);